package com.zt.bigdata.flink

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

/**
  * @ClassName Enviroment
  * @Description
  * @Author zhangtonghy
  * @Date 2019-07-17 17:06
  * @Copyright: 版权所有 (C) zt zt.
  * @注意 ：本内容仅限于zt内部传阅，禁止外泄以及用于其他的商业目的
  **/
class StreamEnvironment {
  def init(parallelism: Int): StreamExecutionEnvironment = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.setParallelism(parallelism)
    env
  }
}
